package cn.doitedu.kafka.topic;

import kafka.admin.TopicCommand;

/***
 * @author hunter.d
 * @qq 657270652
 * @wx haitao-duan
 * @date 2020/11/14
 **/
public class TopicAdminDemo {

    public static void main(String[] args) {
        String[] options = new String[]{
                "--topic","tpc_2",
                "--create",
                "--zookeeper","doitedu01:2181,doitedu02:2181,doitedu03:2181",
                "replication-factor","2",
                "partitions","1"
        };
        TopicCommand.main(options);



    }
}
